package com.sy.ecommerce.stream.sy;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * <h1>自定义输入信道</h1>
 * */
public interface SySink {

    String INPUT = "syInput";

    /** 输入信道的名称是 syInput, 需要使用 Stream 绑定器在 yml 文件中配置*/
    @Input(SySink.INPUT)
    SubscribableChannel syInput();
}
